package com.ly.integral.consumer;

import com.alibaba.fastjson.TypeReference;
import com.ass.rocketmq.constant.MQTopic;
import com.ass.rocketmq.consumer.AbstractConcurrencyPushConsumer;
import lombok.Getter;
import org.springframework.stereotype.Component;

@Component
public class TestConsumer extends AbstractConcurrencyPushConsumer<String> {


    @Getter
    private final TypeReference<String> model = new TypeReference<String>(){};

    @Getter
    private final MQTopic mqTopic = MQTopic.TEST;

    @Override
    protected void handler(String model, String keys) {
        System.out.println("TEST消费者："+model);
    }


}
